
public void fillJob(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment environment,site.teamo.biu.flink.sdk.job.JobContext context){
    %s
}
